bdb7bb16facda0fbe266390bd3213f092d02c0dc,src/java/org/apache/cassandra/hadoop/pig/CqlStorage.java,CqlStorage,cqlColumnToObj,#IColumn#CfDef#,188
Before Change
Map<ByteBuffer,AbstractType> validators = getValidatorMap(cfDef);
if (validators.get(col.name()) == null)
{
Map<MarshallerType, AbstractType> marshallers = getDefaultMarshallers(cfDef);
return marshallers.get(MarshallerType.DEFAULT_VALIDATOR).compose(col.value());
}
else
return validators.get(col.name()).compose(col.value());
After Change
// standard
Map<ByteBuffer,AbstractType> validators = getValidatorMap(cfDef);
if (validators.get(col.name()) == null)
return cassandraToObj(getDefaultMarshallers(cfDef).get(MarshallerType.DEFAULT_VALIDATOR), col.value());
else
return cassandraToObj(validators.get(col.name()), col.value());
}